package com.abyss.function;


import com.abyss.bean.CleanBean;
import org.apache.flink.api.java.functions.KeySelector;

/**
 * @Date 2020/9/16
 * 通用分组函数
 */
public class KeyFunction implements KeySelector<CleanBean,String> {
    @Override
    public String getKey(CleanBean value) throws Exception {
        return value.getSecCode();
    }
}